package com.test.kfk.config;

import org.springframework.context.annotation.Configuration;


/**
 * @author chen_lei
 * @date 2020/11/18 11:02
 */
@Configuration
public class Cfg {

//    /**
//     * 自动创建  分区只能增大不能减小  副本数尽量 >=3  保证数据的安全性
//     * @return
//     */
//    @Bean("topic1")
//    public NewTopic topic1(){
//        return new NewTopic("topic1",4, (short) 3);
//    }
//
//    @Bean("topic2")
//    public NewTopic topic2(){
//        return new NewTopic("topic2",4, (short) 3);
//    }
}
